from app.core.logger import logger, TraceID
async def run():
    TraceID.set() # 每次任务生成新的TraceID
    logger.info("Heavy task is running")
    